package com.money.activemq;

import com.money.domain.Money;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ScheduledMessage;

import javax.jms.*;
import java.io.Serializable;

public class ActiveMQTopicProducer {


    private static final String USERNAME= ActiveMQConnection.DEFAULT_USER; // 默认的连接用户名
    private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD; // 默认的连接密码
    private static final String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL; // 默认的连接地址


    /**
     * 发送消息    静态类
     * @param session        会话对象，创建本次会话的基本配置
     * @param messageProducer 消息生产者对象，将本次消息发送给Topic
     * @throws Exception
     */
    public static void sendMessage(Session session, MessageProducer messageProducer, Serializable serializable,Long time)throws Exception{
            //创建消息的格式（以这种格式发送）： TextMessage
//            TextMessage message=session.createTextMessage("ActiveMQ 发送过来的消息"+i+"第三次");
            ObjectMessage objectMessage = session.createObjectMessage();
            objectMessage.setObject(serializable);
            objectMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);//延迟时间,毫秒
        //后台打印
            System.out.println("发送消息："+"ActiveMQ 发送过来的消息"+serializable.toString());
            //将消息发送给Queue
//            MapMessage mapMessage = session.createMapMessage();
//            mapMessage.setLong(message.getJMSMessageID(),);
            messageProducer.send(objectMessage);
    }
    public static void sendMessageByTopic(String topic, Serializable serializable,Long time) {

        ConnectionFactory connectionFactory; // 连接工厂
        Connection connection = null; // 连接
        Session session; // 会话 接受或者发送消息的线程
        Destination destination; // 消息的目的地
        MessageProducer messageProducer; // 消息生产者
        // 实例化连接工厂
        connectionFactory=new ActiveMQConnectionFactory(ActiveMQTopicProducer.USERNAME, ActiveMQTopicProducer.PASSWORD, ActiveMQTopicProducer.BROKEURL);

        try {
            connection=connectionFactory.createConnection(); // 通过连接工厂获取连接
            connection.start(); // 启动连接
            session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 创建Session
            destination=session.createTopic(topic);//创建消息发布队列
            messageProducer=session.createProducer(destination); // 创建消息生产者
            // 发送消息 ，本质上是将TextMessage类型的消息发送给Queue这个消息队列，这是消息的目的地
            sendMessage(session, messageProducer,serializable,time);
            session.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            if(connection!=null){
                try {
                    connection.close();
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    public static void main(String[] args) {
        ActiveMQTopicProducer.sendMessageByTopic("A",null,6000L);
    }
}
